/*
 * Copyright (c) 2017, 1DAOYUN and/or its affiliates. All rights reserved.
 * 1DAOYUN PROPRIETARY/CONFIDENTIAL. Use is subject to license terms.
 */
package com.iot.nev.gateway.router;

import com.iot.nev.gateway.server.GatewayServer;

/**
 * 数据读取后，交给路由器进行传输，路由器的实现可以直接调用，如果Kafka，也可以走协议
 * http/mqtt基于应用的协议等不建议再走TCP/UDP。
 * 目前测试版本，基于Kafka进行测试，传递参数String。
 * 
 * @author Song Xueyong
 * @since V1.0
 * 
 */
//https://www.confluent.io/product/connectors/
public interface Router {
	
	/**
	 * 获得网关。
	 * @return
	 */
	public GatewayServer getGateway();
	
	/**
	 * 发布消息。
	 * @param message
	 */
	public void publish(String message);

}
